package com.we.flink.userlabelplatform.table;

import java.sql.Timestamp;

public class TableTxxyOrderResultCallback {
    public static final String KFKTABLE = "fdm.hhl01_txxy_order_result_callback";
    public static final String QUERYSQL =
            "select uid, "
                    + "if(trade_time_end is null, TIMESTAMP '1970-01-01 08:00:00.000000', trade_time_end) as trade_time_end "
                    + "from "
                    + KFKTABLE
                    + " where status = 1 and delete_time is null and uid is not null";

    /** default null column */
    public long uid;

    public Timestamp trade_time_end;
    //    public int status; //状态 1: 支付成功  -1 支付失败

    public TableTxxyOrderResultCallback() {}

    public TableTxxyOrderResultCallback(long uid, Timestamp trade_time_end) {
        this.uid = uid;
        this.trade_time_end = trade_time_end;
    }

    @Override
    public String toString() {
        return "TableTxxyOrderResultCallback{"
                + "uid="
                + uid
                + ", trade_time_end="
                + trade_time_end
                + '}';
    }

    public long getUid() {
        return uid;
    }

    public Timestamp getTrade_time_end() {
        return trade_time_end;
    }
}
